package com.gitee.xhs.customFunction;

import com.gitee.xhs.sampleRecod.transactionRecord.Transaction;
import org.apache.flink.api.common.functions.FilterFunction;

/**
 * @author BigHead
 * @date 2022/7/19 16:08
 * @description OperatorIterativeReMapFunction
 */
public class OperatorIterativeLoopFilter implements FilterFunction<Transaction> {

    @Override
    public boolean filter(Transaction value) throws Exception {
        return (double) value.getAccountId() != value.getAmount();
    }

}
